package top.jolyoulu.core.framework.dao

import org.apache.spark.rdd.RDD
import top.jolyoulu.core.framework.common.TDao
import top.jolyoulu.core.framework.util.EnvUtil

/**
 * @Author: JolyouLu
 * @Date: 2024/5/15 17:59
 * @Description
 */
class WordCountDao extends TDao{

  def readFile(path: String): RDD[String] = {
    EnvUtil.take().textFile(path)
  }

}
